8e391de074a22a580bd7074ca74aa592e86b2540,modules/riemann/src/main/java/com/spotify/ffwd/riemann/RiemannInputPlugin.java,RiemannInputPlugin,RiemannInputPlugin,#ProtocolFactory#RetryPolicy#,48

Before Change


            .or(ProtocolFactory.defaultFor())
            .protocol(DEFAULT_PROTOCOL, DEFAULT_PORT);
        this.protocolServer = parseProtocolServer();
        this.retry = Optional.fromNullable(retry).or(new RetryPolicy.Exponential());
    }

    private Class<? extends ProtocolServer> parseProtocolServer() {

After Change


            .orElseGet(ProtocolFactory.defaultFor())
            .protocol(DEFAULT_PROTOCOL, DEFAULT_PORT);
        this.protocolServer = parseProtocolServer();
        this.retry = Optional.ofNullable(retry).orElseGet(() -> new RetryPolicy.Exponential());
    }

    private Class<? extends ProtocolServer> parseProtocolServer() {